f5aeaba4a24fdeafc5ae0f4e69336902346c6bf1,src/main/java/io/vertx/ext/stomp/DefaultNackHandler.java,DefaultNackHandler,handle,#ServerFrame#,20

Before Change


        sf.connection().close();
        return;
      } else {
        transaction.addFrameToTransaction(sf.frame());
        Frames.handleReceipt(sf.frame(), sf.connection());
        // Nothing else in transactions.
        return;

After Change


        connection.close();
        return;
      } else {
        if (!transaction.addFrameToTransaction(sf.frame())) {
          // Frame not added to transaction
          Frame errorFrame = Frames.createErrorFrame("Frame not added to transaction",
              Headers.create(Frame.ID, id, Frame.TRANSACTION, txId),
              "Message delivery failed - the frame cannot be added to the transaction - the number of allowed thread " +
                  "may have been reached");
          connection.handler().unregisterTransactionsFromConnection(connection);
          connection.write(errorFrame);
          connection.close();
          return;
        }
        Frames.handleReceipt(sf.frame(), connection);
        // Nothing else in transactions.
        return;